package cn.neo.hhmq.server;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * 消息订阅
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
public class MessageSubscription {

    private String topic;
    private String consumerId;
    // 消费消息的游标
    private int offset = -1;
}
